package com.cryann.mqttserver.service;

import com.cryann.mqttserver.modle.MqttSendMessage;
import io.netty.channel.Channel;
import io.netty.handler.codec.mqtt.MqttPublishMessage;


/**
 * @author cRyann
 * @date 2018/12/21 0021 16:38
 * @description:
 */
public interface MsgStoreService {

    MqttSendMessage storeMsg(Channel channe, MqttPublishMessage mqttMessage);

    MqttSendMessage peekMsg(Channel channe);

    MqttSendMessage pollMsg(Channel channe);

    MqttSendMessage conversionMsg(Channel channel,MqttPublishMessage mqttMessage);

}
